AWS CDK で、Kinesis Data streams をターゲットとした EventBridge Rules に DLQ を簡単に設定可能になりました

import * as events from 'aws-cdk-lib/aws-events';
import * as event_targets from 'aws-cdk-lib/aws-events-targets';
import * as kinesis from 'aws-cdk-lib/aws-kinesis';
import * as cdk from 'aws-cdk-lib';
import { Construct } from 'constructs';

export class CdkSampleStack extends cdk.Stack {
  constructor(scope: Construct, id: string) {
    super(scope, id);

    const myKinesisStream = new kinesis.Stream(this, 'MyKinesisStream');

    const everyMinuteEventRule = new events.Rule(this, 'EveryMinuteEventRule', {
      schedule: events.Schedule.rate(cdk.Duration.minutes(1)),
    });

    everyMinuteEventRule.addTarget(
      new event_targets.KinesisStream(myKinesisStream)
      // DLQ を設定しない
    );
  }
}

npm i aws-cdk-lib@latest aws-cdk@latest

import * as events from 'aws-cdk-lib/aws-events';
import * as event_targets from 'aws-cdk-lib/aws-events-targets';
import * as sqs from 'aws-cdk-lib/aws-sqs';
import * as kinesis from 'aws-cdk-lib/aws-kinesis';
import * as cdk from 'aws-cdk-lib';
import { Construct } from 'constructs';

export class CdkSampleStack extends cdk.Stack {
  constructor(scope: Construct, id: string) {
    super(scope, id);

    const myKinesisStream = new kinesis.Stream(this, 'MyKinesisStream');

    const myQueue = new sqs.Queue(this, 'MyQueue');

    const everyMinuteEventRule = new events.Rule(this, 'EveryMinuteEventRule', {
      schedule: events.Schedule.rate(cdk.Duration.minutes(1)),
    });

    everyMinuteEventRule.addTarget(
      new event_targets.KinesisStream(myKinesisStream, {
        deadLetterQueue: myQueue, // DLQ を設定
      })
    );
  }
}

$ git diff lib/cdk-sample-stack.ts
diff --git a/lib/cdk-sample-stack.ts b/lib/cdk-sample-stack.ts
index 405c420..24bb7d1 100644
--- a/lib/cdk-sample-stack.ts
+++ b/lib/cdk-sample-stack.ts
@@ -1,5 +1,6 @@
 import * as events from 'aws-cdk-lib/aws-events';
 import * as event_targets from 'aws-cdk-lib/aws-events-targets';
+import * as sqs from 'aws-cdk-lib/aws-sqs';
 import * as kinesis from 'aws-cdk-lib/aws-kinesis';
 import * as cdk from 'aws-cdk-lib';
 import { Construct } from 'constructs';
@@ -10,12 +11,16 @@ export class CdkSampleStack extends cdk.Stack {

     const myKinesisStream = new kinesis.Stream(this, 'MyKinesisStream');

+    const myQueue = new sqs.Queue(this, 'MyQueue');
+
     const everyMinuteEventRule = new events.Rule(this, 'EveryMinuteEventRule', {
       schedule: events.Schedule.rate(cdk.Duration.minutes(1)),
     });

     everyMinuteEventRule.addTarget(
-      new event_targets.KinesisStream(myKinesisStream)
+      new event_targets.KinesisStream(myKinesisStream, {
+        deadLetterQueue: myQueue,
+      })
     );
   }
 }

$ npx cdk diff
Stack CdkSampleStack
Hold on while we create a read-only change set to get a diff with accurate replacement information (use --no-change-set to use a less accurate but faster template-only diff)
Resources
[+] AWS::SQS::Queue MyQueue MyQueueE6CA6235
[~] AWS::Events::Rule EveryMinuteEventRule EveryMinuteEventRule061EE897
 └─ [~] Targets
     └─ @@ -6,6 +6,14 @@
        [ ]     "Arn"
        [ ]   ]
        [ ] },
        [+] "DeadLetterConfig": {
        [+]   "Arn": {
        [+]     "Fn::GetAtt": [
        [+]       "MyQueueE6CA6235",
        [+]       "Arn"
        [+]     ]
        [+]   }
        [+] },
        [ ] "Id": "Target0",
        [ ] "RoleArn": {
        [ ]   "Fn::GetAtt": [

✨  Number of stacks with differences: 1